package com.lzy.elasticserch.result;

import com.lzy.canal.model.CanalMessageEntryResultData;
import org.elasticsearch.action.DocWriteRequest;

import java.util.List;

/**
 * 结果转换器
 *
 */
public interface ResultConvert {

    /**
     * canal 解析消息返回数据转换为 elasticsearch 请求数据
     *
     * @param data 数据
     * @return
     */
    DocWriteRequest<?>[] convert(List<CanalMessageEntryResultData> data);


}
